package com.cetccloud.ap.proxy.coord;

import com.cetccloud.ap.proxy.common.ProxyContext;
import reactor.core.publisher.MonoSink;

public interface Coord {

    default void registerSink(String identity, MonoSink sink) {
        registerSink(identity, sink, null);
    }

    void registerSink(String identity, MonoSink sink, ProxyContext context);

    void success(String identity, Object message);

    void error(String identity, String message);
}
